package mqtt

import "gopkg.in/ffmt.v1"

func SubMqtt() {
	ffmt.Puts("开始监听")
	err := MqClient.Subscribe(func(c *Client, msg *Message) {
		//你的操作
		switch msg.Topic {
			case "mqtt":
				//主题mqtt的业务
				ffmt.Println("主题mqtt的业务")
			case "zsg":
				//主题zsg的业务

		
		}
	}, 2, topics...)

	if err != nil {
		ffmt.Puts(UserName +"错误1,原因:"+err.Error())
	}
}
